package com.hardy.demo.hystrix;

import com.netflix.hystrix.*;
import rx.Observable;
import rx.Observer;
import rx.observables.AsyncOnSubscribe;
import rx.observables.SyncOnSubscribe;

import java.util.concurrent.TimeUnit;

/**
 * Author: Hardy
 * Date:   2021/3/11
 * Description:
 **/
public class Option extends HystrixObservableCommand {

    public Option() {
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("Group")));
    }

    @Override
    protected Observable construct() {
//        return new Observable(new Observable.OnSubscribe());
        return null;
    }
}
